package com.camel;

import java.io.IOException;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class MessageProcessor implements Processor{

	@Override
	public void process(Exchange exchange) throws Exception {
		System.out.println(">>>>Exchange: " +exchange);
		
		System.out.println(">>>>Body class:" + exchange.getIn().getBody().getClass());
		//System.out.println(">>>>Body: " + exchange.getIn().getBody(IMessage.class));
		throw new IOException("Testing error handler");
	}

}
